package com.central.scheduler.plugin.task.flink.sql;

/**
 * @author Tindy
 * @date 2022/5/6
 * @describe
 */
public class FlinkSqlConstants {
    private FlinkSqlConstants() {
        throw new IllegalStateException("Utility class");
    }

    /**
     * flink
     */
    public static final String FLINK_YARN_CLUSTER = "yarn-cluster";
    public static final String FLINK_RUN_MODE = "-m";
    public static final String FLINK_YARN_SLOT = "-ys";
    public static final String FLINK_APP_NAME = "-ynm";
    public static final String FLINK_QUEUE = "-yqu";
    public static final String FLINK_TASK_MANAGE = "-yn";

    public static final String FLINK_JOB_MANAGE_MEM = "-yjm";
    public static final String FLINK_TASK_MANAGE_MEM = "-ytm";
    public static final String FLINK_MAIN_CLASS = "-c";
    public static final String FLINK_PARALLELISM = "-p";
    public static final String FLINK_SHUTDOWN_ON_ATTACHED_EXIT = "-sae";
    public static final String FLINK_SAVEPOINT_PATH="-s";
    public static final String FLINK_CLASS_PATH="-C";
}
